from celery import Celery
"""
    # 1. 创建任务
    # 2. 创建Celery实例
    # 3. 在celery中 设置 任务,broker
    # 4. worker

#1. celery 是一个 即插即用的任务队列
# celery 是需要和 django(当前的工程) 进行交互的
# 让celery加载当前的工程的默认配置
"""
# 1. 创建任务
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE']='mall.settings'
# 2. 创建Celery实例
app = Celery(main='celery_tasks')
# ３．设置broker
app.config_from_object('celery_tasks.config')
# 4. 在celery自动检测中 设置 任务,broker
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.mail'])
# 5. worker去执行任务
# 需要在虚拟环境中 执行指令
# celery -A celery实例对象的文件路径 worker -l info
#celery -A clery_tasks.main worker -l info